
// Standard library
#include <iostream>
#include <string>

// JSON library
#include <nlohmann/json.hpp>
using json = nlohmann::json;

// Utilities

// Our reactive stream implementation
#include "filter.h"
#include "join.h"
#include "sink.h"

// Service implementation
#include "service.h"
#include<boost/asio.hpp>

int main(int argc, char* argv[])
{
    boost::asio::io_service event_loop;
    
    auto sink_to_err = sink([] (const auto & message) {
        std::cerr << message << std::endl;
    }); 
    auto pipeline = service(event_loop) | sink_to_err;   
}